package com.imooc.spark.streaming.kafka;

/**
 * @author yuyon26@126.com
 * @description
 * @date 2018/10/19 0:18
 */
public class MyKafkaProducerConsumerTest {

    public static void main(String[] args){
        //new MyKafkaProducer(MyKafkaProperties.TOPIC).start();
        new MyKafkaConsumer(MyKafkaProperties.TOPIC).start();
    }
}
